package common.mq.sender.service;

import org.apache.thrift.TException;

import bma.common.langutil.log.filelog.AsyncFileLog;
import common.mq.sender.thrift.TConsumerService;
import common.mq.sender.thrift.TRequest;
import common.mq.sender.thrift.TResponse;

public class ConsumerServiceThrift implements TConsumerService.Iface{

	final org.slf4j.Logger log = org.slf4j.LoggerFactory.getLogger(ConsumerServiceThrift.class);

	private AsyncFileLog fileLog;

	public void setFileLog(AsyncFileLog fileLog) {
		this.fileLog = fileLog;
	}

	@Override
	public TResponse receiveMessage(TRequest request) throws TException {
		return new TResponse(0, "成功！");
	}
}
